package com.example.listener;

import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Component;


@Component
public class RocketListener {
    
    @StreamListener("input")
    public void input(Message<String> message) {
        System.out.println(message);
    }

    @StreamListener("ticketing")
    public void ticketing(Message<String> message) {
        System.out.println(message);
    }

    @StreamListener("refund")
    public void refund(Message<String> message) {
        System.out.println(message);
    }

    @StreamListener("change")
    public void change(Message<String> message) {
        System.out.println(message);
    }
}
